package com.mriassl.rabbitmq.base;

public abstract class AbstractConsumer extends BaseConnection {

	protected abstract void handle() throws Exception;
	
	public void receiveMsg() throws Exception{
		if(channel == null){
			init();
		}
		handle();
	} 
	
}
